package com.spring_activemq.mq.consumer;

import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.springframework.jms.listener.SessionAwareMessageListener;

public class ConsumerMessageListener implements SessionAwareMessageListener<TextMessage> {

	public void onMessage(TextMessage message, Session session) throws JMSException {
		System.out.println("p2p:" + message.getText() + "=====");
	}

}
